co.wrap - Code Metrics - Equim-chan/csu-ems-api - Measure and Improve Code Quality continuously with Scrutinizer

co.wrap B
last analyzed 2017-02-17 12:36 UTC

↳ Parent: co.wrap

Complexity

Conditions	6
Paths	7

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	6
c	1
b	0
f	0
nc	7
nop	1
dl	0
loc	35
rs	8.439

'use strict';

const express    = require('express'),
      superagent = require('superagent'),
      cheerio    = require('cheerio'),
      colors     = require('colors'),

      program    = require('commander'),
      moment     = require('moment'),
      co         = require('co'),
      thunkify   = require('thunkify'),
      access     = require('./lib/access.js');

program
    .option('-h, --help')
    .option('-V, --version')
    .option('-p, --port [value]', parseInt)

    .option('-v, --verbose')
    .parse(process.argv);

if (!program.help || !program.version) {
    console.log(
`${`CSUEMS API v${require('./package').version}
by The Liberators`.rainbow}${program.help ? '' :
`

Preparation:
  ${'(This section is WIP)'.grey}

Usage:
  npm start [-- <options...>]

Options:
  -h, --help          print this message and exit.
  -V, --version       print the version and exit.
  -v, --verbose       enable verbose log, by default only errors are logged.
  -p, --port [value]  specify a port to listen, process.env.PORT || 2333 by default.

Examples:
  $ npm start -- -p 43715               # listening to 43715
  $ forever start app.js                # deploy with forever as daemon (root access recommended)
  $ pm2 start -i 0 -n "csuapi" app.js   # deploy with pm2 as daemon  (root access recommended)`}`);
    process.exit(0);
}

superagent.Request.prototype.endThunk = thunkify(superagent.Request.prototype.end);

const port = program.port || process.env.PORT || 2333,
      app = express();

const logging = (log) => console.log(`${moment().format('[[]YY-MM-DD HH:mm:ss[]]')} ${log}`);

const verbose = (log) => program.verbose && logging(log);

// 根据系统时间计算当前学期
const getSem = () => {
    let now = new Date();
    let month = now.getMonth();
    let year = now.getFullYear();
    return month <= 6 ? `${year - 1}-${year}-${month > 0 ? 2 : 1}` : `${year}-${year + 1}-1`;
};

// 获取文档
app.get('/doc', (req, res) => res.sendFile(`${__dirname}/doc/API.html`));

// 查成绩API，通过GET传入用户名和密码
app.get(/^\/g(?:|rades)$/, co.wrap(function *(req, res) {
    // 检查参数
    if (!req.query.id || !req.query.pwd || (req.query.sem && !(/^20\d{2}-20\d{2}-[1-2]$/).test(req.query.sem))) {
        res.status(404).json({ error: "参数不正确" });
        return;
    }

    // 记录处理用时
    let start = new Date();
    verbose('Started to query the grades: '.cyan + req.query.id.yellow);

    // 登录，获取headers
    let headers;
    try {
        headers = yield access.login(req.query.id, req.query.pwd);
    } catch (errMsg) {
        logging(errMsg.inner.red);
        res.status(404).json({ error: errMsg.public });
        return;
    }
    verbose('Successfully logged in.'.green);

    // 进入成绩页面
    let ires;
    try {
        // 实际上xnxq01id为空的时候和GET这个URL的效果是一样的，都是查询所有学期
        ires = yield superagent
                         .post('http://csujwc.its.csu.edu.cn/jsxsd/kscj/yscjcx_list')
                         .set(headers)
                         .type('form')
                         .send({ xnxq01id: req.query.sem })
                         .endThunk();
    } catch (err) {
        logging(`Failed to get grades page\n${err.stack}`.red);
        res.status(404).json({ error: '无法进入成绩页面' });
        return;
    } finally {
        // 异步登出
        co(function *() {
            try {
                yield access.logout(headers);
            } catch (errMsg) {
                logging(errMsg.inner.red);
                return;

            }
            verbose('Successfully logged out: '.green + req.query.id.yellow);
        });
    }
    verbose('Successfully entered grades page.'.green);

    let $ = cheerio.load(ires.text);

    let top = $('#Top1_divLoginName').text();
    let result = {
        name: top.match(/\s.+\(/)[0].replace(/\s|\(/g, ''),
        id: top.match(/\(.+\)/)[0].replace(/\(|\)/g, ''),
        grades: {},
        'subject-count': 0,
        failed: {},
        'failed-count': 0,
    };
    // 获取成绩列表
    $('#dataList tr').each(function (index) {
        if (index === 0) {
            return;
        }

        let element = $(this).find('td');

        let title = element.eq(3).text().match(/].+$/)[0].substring(1);
        let item = {
            sem: element.eq(2).text(),
            reg: element.eq(4).text(),
            exam: element.eq(5).text(),
            overall: element.eq(6).text()
        };
        if (req.query.details) {
            item.id = element.eq(3).text().match(/\[.+\]/)[0].replace(/\[|\]/g, '');
            item.attr = element.eq(8).text();
            item.genre = element.eq(9).text();
            item.credit = element.eq(7).text();
        }

        // 如果有补考记录，则以最高分的为准(暂不考虑NaN)
        if (title in result.grades && item.overall < result.grades[title].overall) {
            return;
        }

        result.grades[title] = item;

        // 挂科判定
        if (element.eq(6).css('color')) {
            result.failed[title] = item;
        } else {
            delete result.failed[title];
        }
    });

    result['subject-count'] = Object.keys(result.grades).length;
    result['failed-count'] = Object.keys(result.failed).length;

    res.json(result);
    verbose(`Successfully responded. (req -> res processed in ${new Date() - start}ms)`.green);
}));

// 查考试API，通过GET传入用户名和密码
app.get(/^\/e(?:|xams)$/, co.wrap(function *(req, res) {
    if (!req.query.id || !req.query.pwd || (req.query.sem && !(/^20\d{2}-20\d{2}-[1-2]$/).test(req.query.sem))) {
        res.status(404).json({ error: "参数不正确" });
        return;
    }

    let start = new Date();
    verbose('Started to query the exams: '.cyan + req.query.id.yellow);

    let headers;
    try {
        headers = yield access.login(req.query.id, req.query.pwd);
    } catch (errMsg) {
        logging(errMsg.inner.red);
        res.status(404).json({ error: errMsg.public });
        return;
    }
    verbose('Successfully logged in.'.green);

    let ires;
    let _sem = req.query.sem || getSem();
    try {
        ires = yield superagent
                         .post('http://csujwc.its.csu.edu.cn/jsxsd/xsks/xsksap_list')
                         .set(headers)
                         .type('form')
                         .send({
                             xqlbmc: '',
                             xnxqid: _sem,
                             xqlb: ''
                         })
                         .endThunk();
    } catch (err) {
        logging(`Failed to reach exams page\n${err.stack}`.red);
        res.status(404).json({ error: '无法进入考试页面' });
        return;
    } finally {
        co(function *() {
            try {
                yield access.logout(headers);
                verbose('Successfully logged out: '.green + req.query.id.yellow);
            } catch (errMsg) {
                logging(errMsg.inner.red);
            }
        });
    }
    verbose('Successfully entered exams page.'.green);

    let $ = cheerio.load(ires.text);

    let top = $('#Top1_divLoginName').text();
    let result = {
        name: top.match(/\s.+\(/)[0].replace(/\s|\(/g, ''),
        id: top.match(/\(.+\)/)[0].replace(/\(|\)/g, ''),
        sem: _sem,
        exams: {},
        'exams-count': 0,
    };
    $('#dataList tr').each(function (index) {
        if (index === 0) {
            return;
        }

        let element = $(this).find('td');

        let title = element.eq(3).text();
        let item = {
            time: element.eq(4).text(),
            location: element.eq(5).text(),
            seat: element.eq(6).text()
        };

        result.exams[title] = item;
        result['exams-count']++;
    });

    res.json(result);
    verbose(`Successfully responded. (req -> res processed in ${new Date() - start}ms)`.green);
}));

app.listen(port, () => {
    logging(`The API is now running on port ${port}. Verbose logging is ${program.verbose ? 'enabled' : 'disabled'}`.green);
});


1			'use strict';
2
3			const express = require('express'),
4			superagent = require('superagent'),
5			cheerio = require('cheerio'),
6			colors = require('colors'),
			0 ignored issues – show Unused Code introduced 2017-01-19 08:07 UTC by Report Bug Copy Issue Report The constant `colors` seems to be never used. Consider removing it. Loading history...
7			program = require('commander'),
8			moment = require('moment'),
9			co = require('co'),
10			thunkify = require('thunkify'),
11			access = require('./lib/access.js');
12
13			program
14			.option('-h, --help')
15			.option('-V, --version')
16			.option('-p, --port [value]', parseInt)
			0 ignored issues – show Bug introduced 2017-01-10 09:20 UTC by Report Bug Copy Issue Report The variable `parseInt` seems to be never declared. If this is a global, consider adding a `/** global: parseInt */` comment. This checks looks for references to variables that have not been declared. This is most likey a typographical error or a variable has been renamed. To learn more about declaring variables in Javascript, see the MDN. Loading history...
17			.option('-v, --verbose')
18			.parse(process.argv);
19
20			if (!program.help \|\| !program.version) {
21			console.log(
22			`${`CSUEMS API v${require('./package').version}
23			by The Liberators`.rainbow}${program.help ? '' :
24			`
25
26			Preparation:
27			${'(This section is WIP)'.grey}
28
29			Usage:
30			npm start [-- <options...>]
31
32			Options:
33			-h, --help print this message and exit.
34			-V, --version print the version and exit.
35			-v, --verbose enable verbose log, by default only errors are logged.
36			-p, --port [value] specify a port to listen, process.env.PORT \|\| 2333 by default.
37
38			Examples:
39			$ npm start -- -p 43715 # listening to 43715
40			$ forever start app.js # deploy with forever as daemon (root access recommended)
41			$ pm2 start -i 0 -n "csuapi" app.js # deploy with pm2 as daemon (root access recommended)`}`);
42			process.exit(0);
43			}
44
45			superagent.Request.prototype.endThunk = thunkify(superagent.Request.prototype.end);
46
47			const port = program.port \|\| process.env.PORT \|\| 2333,
48			app = express();
49
50			const logging = (log) => console.log(`${moment().format('[[]YY-MM-DD HH:mm:ss[]]')} ${log}`);
51
52			const verbose = (log) => program.verbose && logging(log);
53
54			// 根据系统时间计算当前学期
55			const getSem = () => {
56			let now = new Date();
57			let month = now.getMonth();
58			let year = now.getFullYear();
59			return month <= 6 ? `${year - 1}-${year}-${month > 0 ? 2 : 1}` : `${year}-${year + 1}-1`;
60			};
61
62			// 获取文档
63			app.get('/doc', (req, res) => res.sendFile(`${__dirname}/doc/API.html`));
64
65			// 查成绩API，通过GET传入用户名和密码
66			app.get(/^\/g(?:\|rades)$/, co.wrap(function *(req, res) {
67			// 检查参数
68			if (!req.query.id \|\| !req.query.pwd \|\| (req.query.sem && !(/^20\d{2}-20\d{2}-[1-2]$/).test(req.query.sem))) {
69			res.status(404).json({ error: "参数不正确" });
70			return;
71			}
72
73			// 记录处理用时
74			let start = new Date();
75			verbose('Started to query the grades: '.cyan + req.query.id.yellow);
76
77			// 登录，获取headers
78			let headers;
79			try {
80			headers = yield access.login(req.query.id, req.query.pwd);
81			} catch (errMsg) {
82			logging(errMsg.inner.red);
83			res.status(404).json({ error: errMsg.public });
84			return;
85			}
86			verbose('Successfully logged in.'.green);
87
88			// 进入成绩页面
89			let ires;
90			try {
91			// 实际上xnxq01id为空的时候和GET这个URL的效果是一样的，都是查询所有学期
92			ires = yield superagent
93			.post('http://csujwc.its.csu.edu.cn/jsxsd/kscj/yscjcx_list')
94			.set(headers)
95			.type('form')
96			.send({ xnxq01id: req.query.sem })
97			.endThunk();
98			} catch (err) {
99			logging(`Failed to get grades page\n${err.stack}`.red);
100			res.status(404).json({ error: '无法进入成绩页面' });
101			return;
102			} finally {
103			// 异步登出
104			co(function *() {
105			try {
106			yield access.logout(headers);
107			} catch (errMsg) {
108			logging(errMsg.inner.red);
109			return;
			0 ignored issues – show Comprehensibility Bug introduced 2017-01-22 15:41 UTC by Report Bug Copy Issue Report Usage of the `return` statement in a finally clause is discouraged. This construct may mask errors and makes debugging difficult. Loading history...
110			}
111			verbose('Successfully logged out: '.green + req.query.id.yellow);
112			});
113			}
114			verbose('Successfully entered grades page.'.green);
115
116			let $ = cheerio.load(ires.text);
117
118			let top = $('#Top1_divLoginName').text();
119			let result = {
120			name: top.match(/\s.+\(/)[0].replace(/\s\|\(/g, ''),
121			id: top.match(/\(.+\)/)[0].replace(/\(\|\)/g, ''),
122			grades: {},
123			'subject-count': 0,
124			failed: {},
125			'failed-count': 0,
126			};
127			// 获取成绩列表
128			$('#dataList tr').each(function (index) {
129			if (index === 0) {
130			return;
131			}
132
133			let element = $(this).find('td');
134
135			let title = element.eq(3).text().match(/].+$/)[0].substring(1);
136			let item = {
137			sem: element.eq(2).text(),
138			reg: element.eq(4).text(),
139			exam: element.eq(5).text(),
140			overall: element.eq(6).text()
141			};
142			if (req.query.details) {
143			item.id = element.eq(3).text().match(/\[.+\]/)[0].replace(/\[\|\]/g, '');
144			item.attr = element.eq(8).text();
145			item.genre = element.eq(9).text();
146			item.credit = element.eq(7).text();
147			}
148
149			// 如果有补考记录，则以最高分的为准(暂不考虑NaN)
150			if (title in result.grades && item.overall < result.grades[title].overall) {
151			return;
152			}
153
154			result.grades[title] = item;
155
156			// 挂科判定
157			if (element.eq(6).css('color')) {
158			result.failed[title] = item;
159			} else {
160			delete result.failed[title];
161			}
162			});
163
164			result['subject-count'] = Object.keys(result.grades).length;
165			result['failed-count'] = Object.keys(result.failed).length;
166
167			res.json(result);
168			verbose(`Successfully responded. (req -> res processed in ${new Date() - start}ms)`.green);
169			}));
170
171			// 查考试API，通过GET传入用户名和密码
172			app.get(/^\/e(?:\|xams)$/, co.wrap(function *(req, res) {
173			if (!req.query.id \|\| !req.query.pwd \|\| (req.query.sem && !(/^20\d{2}-20\d{2}-[1-2]$/).test(req.query.sem))) {
174			res.status(404).json({ error: "参数不正确" });
175			return;
176			}
177
178			let start = new Date();
179			verbose('Started to query the exams: '.cyan + req.query.id.yellow);
180
181			let headers;
182			try {
183			headers = yield access.login(req.query.id, req.query.pwd);
184			} catch (errMsg) {
185			logging(errMsg.inner.red);
186			res.status(404).json({ error: errMsg.public });
187			return;
188			}
189			verbose('Successfully logged in.'.green);
190
191			let ires;
192			let _sem = req.query.sem \|\| getSem();
193			try {
194			ires = yield superagent
195			.post('http://csujwc.its.csu.edu.cn/jsxsd/xsks/xsksap_list')
196			.set(headers)
197			.type('form')
198			.send({
199			xqlbmc: '',
200			xnxqid: _sem,
201			xqlb: ''
202			})
203			.endThunk();
204			} catch (err) {
205			logging(`Failed to reach exams page\n${err.stack}`.red);
206			res.status(404).json({ error: '无法进入考试页面' });
207			return;
208			} finally {
209			co(function *() {
210			try {
211			yield access.logout(headers);
212			verbose('Successfully logged out: '.green + req.query.id.yellow);
213			} catch (errMsg) {
214			logging(errMsg.inner.red);
215			}
216			});
217			}
218			verbose('Successfully entered exams page.'.green);
219
220			let $ = cheerio.load(ires.text);
221
222			let top = $('#Top1_divLoginName').text();
223			let result = {
224			name: top.match(/\s.+\(/)[0].replace(/\s\|\(/g, ''),
225			id: top.match(/\(.+\)/)[0].replace(/\(\|\)/g, ''),
226			sem: _sem,
227			exams: {},
228			'exams-count': 0,
229			};
230			$('#dataList tr').each(function (index) {
231			if (index === 0) {
232			return;
233			}
234
235			let element = $(this).find('td');
236
237			let title = element.eq(3).text();
238			let item = {
239			time: element.eq(4).text(),
240			location: element.eq(5).text(),
241			seat: element.eq(6).text()
242			};
243
244			result.exams[title] = item;
245			result['exams-count']++;
246			});
247
248			res.json(result);
249			verbose(`Successfully responded. (req -> res processed in ${new Date() - start}ms)`.green);
250			}));
251
252			app.listen(port, () => {
253			logging(`The API is now running on port ${port}. Verbose logging is ${program.verbose ? 'enabled' : 'disabled'}`.green);
254			});
255

Equim-chan / csu-ems-api

co.wrap B last analyzed 2017-02-17 12:36 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

co.wrap B
last analyzed 2017-02-17 12:36 UTC